package com.bangcommunity.bbframe.mq;

/**
 * Created by tanghc on 17/2/3.
 */

import com.bangcommunity.bbframe.mq.producer.QtProducerClient;

public class QtKafkaProducerExample {
    public static void main(String[] args) throws InterruptedException {
        QtProducerClient.getQtProducer().sendSync("t1", "abc");
        QtProducerClient.getQtProducer().sendSync("t1", "abc");
        QtProducerClient.getQtProducer().sendSync("t1", "abc");
        Thread.sleep(1000);
        QtProducerClient.getQtProducer().sendSync("t1", "abc1");
        QtProducerClient.getQtProducer().sendSync("t1", "abc1");
        QtProducerClient.getQtProducer().sendSync("t1", "abc1");
        QtProducerClient.getQtProducer().sendSync("t1", "abc1");
    }
}